package com.example.rxjava1;

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import rx.Observable;

@RestController
public class RxjavaController {

    /**
     * 用于测试rxjava中的Observable，能否被自动订阅，类似于webflux，测试了下，在以netty方式启动时可以被自动订阅，springmvc方式的时候也可以, 环境都是基于Java8
     */
    @GetMapping("/testrxjava")
    public Observable<String> testObservable(){
        return Observable.just("hello rejava");
    }
}
